package org.apache.flink.runtime.cleanup;

import java.util.concurrent.Executor;

import org.apache.flink.configuration.Configuration;
import org.apache.flink.runtime.resourceconsumer.runner.ResourceConsumerRunner;

@FunctionalInterface
public interface CleanupRunnerFactory {
    ResourceConsumerRunner create(
            Configuration configuration,
            Executor cleanupExecutor);
}
